ded8042ba34fbc731ce39e78393d5b07375e8ab4,code/source/tundra/tn/support/queue.java,queue,eachConcurrent,#com.wm.app.tn.delivery.DeliveryQueue#com.wm.lang.ns.NSName#String#IData#number#number#,118
Before Change
if (task == null) {
if (size > 0) {
// wait for first thread to finish; once finished we'll loop again and see if there are now tasks on the queue
awaitOldest(futures);
} else {
// if all threads have finished and there are no more tasks, then exit
break;
After Change
if (task == null) {
if (size > 0) {
// wait for first thread to finish; once finished we'll loop again and see if there are now tasks on the queue
Exception exception = awaitOldest(futures);
if (exception != null) {
exceptions.add(exception);
break;
}
} else {